const mysql = require('mysql');

var connect = mysql.createConnection({
	host: 'localhost',
	port: 3306,
	user: 'root',
	password: 'root',
	database: 'music_db'
})

connect.connect(function (err) {
	if (!err) {
		console.log('数据库连接成功');
	} else {
		console.log('数据库连接失败');
	}
})

// 包装查询函数
var dbQuery = function (sqlStr, value) {
	return new Promise(function (reslove, reject) {
		if (value) {
			connect.query(sqlStr, value, function (err, res) {
				if (err) {
					reject(err);
				} else {
					reslove(res);
				}
			})
		} else {
			connect.query(sqlStr, function (err, res) {
				if (err) {
					reject(err);
				} else {
					reslove(res);
				}
			})
		}
	})
}

module.exports = dbQuery
